#ifndef __STREAM_PUSH_SERVER__
#define __STREAM_PUSH_SERVER__

#include <map>
#include "json.h"
#include "Network/Buffer.h"
#include "Util/util.h"

using namespace std;
using namespace Fdt;

class StreamPushServer{
public:
	static StreamPushServer *instance();

	void RegistRPC();
	bool StartPushStream(const Json::Value &request, const Fdt::BufferMap::Ptr &inMap, Json::Value &response, Fdt::BufferMap::Ptr &outBuffer);
    bool StopPushStream(const Json::Value &request, const Fdt::BufferMap::Ptr &inMap, Json::Value &response, Fdt::BufferMap::Ptr &outBuffer);

private:
	StreamPushServer();
	~StreamPushServer();
};

#endif